package com.navinfo.tripanalysis.service;

import com.navinfo.tripanalysis.pojo.AlgorithmOuterData;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.sql.SparkSession;

/**
 * 保存公共位置协议的服务
 * @author web
 */
public interface SavePointService {
     void save(SparkSession spark, JavaPairRDD<Long, AlgorithmOuterData> pairTidOutData, long day);
}
